package org.zjt.auth.MQ.activemq;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.core.MessageCreator;

public class ActiveMQMsg implements MessageCreator{
	
	private String context;

	public String getContext() {
		return context;
	}

	public void setContext(String context) {
		this.context = context;
	}

	public Message createMessage(Session session) throws JMSException {
		return session.createTextMessage("zhangJuntao"+context);
	}

}
